package com.wdciti.sccp.iot.springvertx.protocols.mqtt;//package org.easyiot.springvertx.protocols.mqtt;
//
//import org.easyiot.springvertx.EndPointVerticle;
//import io.vertx.core.Handler;
//import io.vertx.core.eventbus.EventBus;
//import io.vertx.mqtt.MqttClient;
//import io.vertx.mqtt.messages.MqttPublishMessage;
//
///**
// * @author JINWEN
// */
//public class MqttMsgHandler implements Handler<MqttPublishMessage> {
//
//
//    private final String busAddr;
//    private final EventBus eventBus;
//    private final MqttClient mqttClient;
//
//    public MqttMsgHandler(EventBus eventBus, String busAddr, MqttClient mqttClient) {
//        this.busAddr = busAddr;
//        this.eventBus = eventBus;
//        this.mqttClient = mqttClient;
//    }
//    @Override
//    public void handle(MqttPublishMessage event) {
//
//        eventBus.send(busAddr + EndPointVerticle.IN , event);
//
//    }
//}
